Counter.java

Go to the documentation of this file.

package counter;

import jvn.JvnException;
import jvn.JvnObject;
import jvn.JvnServerImpl;

public class Counter {

        public static void main(String[] args) {
                try {
                        // initialize JVN
                        JvnServerImpl js = JvnServerImpl.jvnGetServer();

                        if (js == null) {
                                System.out.println("Counter stress test problem : cannot create server!");
                        }
                        else {
                                // look up the IRC object in the JVN server
                                // if not found, create it, and register it in the JVN server
                                JvnObject jo = js.jvnLookupObject("Counter",JvnObject.class);
                                if (jo == null) {
                                        jo = js.jvnCreateObject(new IntegerWrapper());
                                        // after creation, I have a write lock on the object
                                        jo.jvnUnLock();
                                        js.jvnRegisterObject("Counter", jo);
                                }
                                while(true) {
                                        try {
                                                // jo.jvnLockWrite(); // Egoistic read.
                                                jo.jvnLockRead();
                                                int number = ((IntegerWrapper) jo.jvnGetObjectState()).read();
                                                jo.jvnUnLock();
                                                System.out.println("Current number is "+number+", next number shall be "+(++number));
                                                jo.jvnLockWrite();
                                                ((IntegerWrapper) jo.jvnGetObjectState()).write(number);
                                                jo.jvnUnLock();
                                        } catch (JvnException je) {
                                                System.out.println("Counter stress test problem : " + je.getMessage());
                                        }
                                }
                        }
                } catch (JvnException je) {
                        System.out.println("Counter stress test problem : " + je.getMessage());
                }
        }
}

---